<?php

namespace app\index\controller;

use support\Request;
use Webman\RedisQueue\Redis;

class IndexController
{

    public function index()
    {

        echo 'index/index/index';
    }

    public function demoQueue()
    {
        // 队列名
        $queue = 'demo_queue';
        // 数据，可以直接传数组，无需序列化
        $data = ['to' => 'tom@gmail.com', 'content' => 'hello'];
        // 投递消息
        //Redis::send($queue, $data);
        // 投递延迟消息，消息会在60秒后处理
        Redis::send($queue, $data, 3);

        return response('redis queue test');
    }

}
